package com.shujia.szt;

import org.apache.hadoop.hive.ql.exec.UDF;

import java.util.ArrayList;

/**
 * hive自定义函数
 */
public class ArraySum extends UDF {

    //方法名必须是evaluate
    //方法的参数就是hive sql需要传进来数类型
    public Double evaluate(ArrayList<Double> array) {

        Double sum = 0.0;
        for (Double d : array) {
            sum += d;
        }

        return sum;
    }
}
